UPDATE "<%= schema %>".streams
SET deleted_at = NOW()
WHERE stream_id = $1;
